package demo.flume;

import org.apache.flume.interceptor.Interceptor;
import org.apache.flume.sink.elasticsearch.ElasticSearchSink;
import org.apache.flume.sink.kafka.KafkaSink;
import org.apache.flume.source.kafka.KafkaSource;
import org.apache.flume.source.taildir.TaildirMatcher;
import org.apache.flume.source.taildir.TaildirSource;

import static org.apache.flume.conf.source.SourceType.TAILDIR;

/**
 * Flume is a distributed, reliable, and available service for efficiently
 * collecting, aggregating, and moving large amounts of streaming event data.
 */
public class FlumeDemo {

    /**
     *
     */
    public void testTailDir() {
        String className = TAILDIR.getClassName();
        TaildirSource tailDirSource = null;
    }

    public void testInterceptor() {
        Interceptor interceptor = null;
    }

    public void testTaildirMatcher(){
        TaildirMatcher a = null;
    }

    public void testKafkaSink(){
        KafkaSink kafkaSink = null;
    }

    public void testKafkaSource(){
        KafkaSource kafkaSink = null;
    }

    public void testElasticSearchSink(){
        ElasticSearchSink kafkaSink = null;
    }
}
